package learn1

import com.rabbitmq.client.AMQP
import com.rabbitmq.client.ConnectionFactory


/**

 @author HSH

 @create 2022-01-05 18:18

 */
class Productor {
    final static QUEUE_NAME = "hello"
    static void main(String[] args) {
        ConnectionFactory factor = new ConnectionFactory()
        factor.host = "127.0.0.1"
        factor.username = "admin"
        factor.password = "admin"
        def connection = factor.newConnection()
        def channel = connection.createChannel()
        /****
         * 生成一个队列
         * 1.队列名称
         * 2.队列里的消息是否持久化 默认消息存储在内存中
         * 3.该队列是否只供一个消费者进行消费 是否进行共享 true 可以多个消费者消费
         * 4.是否自动删除 最后一个消费者断开连接以后 该队列是否自动删除 true 自动删除
         * 5.其他参数
         *
         */
        channel.queueDeclare(QUEUE_NAME,false,false,false,null)
        def message = "hello world"
        /**
         * 发送一个消息
         * 1.发送到那个交换机
         * 2.路由的key是哪个
         * 3.其他的参数消息
         * 4.发送的消息体
         */
        channel.basicPublish("",QUEUE_NAME,null,message.getBytes())
        println "消息发送完毕"
    }
}
